a26011b7d82f89cc06b6850803d764fd7e9489eb,common/src-mapred/org/pentaho/hadoop/mapreduce/GenericTransReduce.java,GenericTransReduce,close,#,300
Before Change
@Override
public void close() throws IOException {
rowProducer.finished();
// Stop the executor if any is defined...
if ( isSingleThreaded() && executor != null ) {
After Change
@Override
public void close() throws IOException {
if ( rowProducer != null ) {
rowProducer.finished();
}
// Stop the executor if any is defined...
if ( isSingleThreaded() && executor != null ) {